from java.io import IOException
from org.apache.hadoop.io import IntWritable, LongWritable, Text
from org.apache.hadoop.mapreduce import Mapper
from org.apache.hadoop.mapreduce.Mapper import Context

class WCMapper (Mapper):
	def map(self, key, value, context):
		print 'word count mapper'
		context.write(IntWritable(1), IntWritable(1))
